package com.fulu.game.bigdata.realtime.config
import java.util.Properties
import org.apache.calcite.interpreter.Sink
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
import org.apache.flink.types.Row

/*
  object KafkaSinkBuilder {

    def createKafkaSink(sink: Sink,topic:String) : FlinkKafkaProducer[(Boolean,Row)] = {

      val props = new Properties()
      props.setProperty("bootstrap.servers",Config.getKafkaServer())

     // val kafkaProducer = new FlinkKafkaProducer[(Boolean,Row)](topic,FlinkKafkaProducer.Semantic.AT_LEAST_ONCE)

    //  kafkaProducer
  //  }
  }
*/

